'''

构造mysql链接

'''
import sys
sys.path.append('../..')
import pymysql
from common.config import *
class MysqlClient( object ):
    def __init__(self):
        self._conn = pymysql.Connect( **config )
        self.cursor = self._conn.cursor( pymysql.cursors.DictCursor)
    #随机查询一条状态为0的数据
    def randTask(self,name):
        self.cursor.execute( common["rand_task"].format( name=name ))
        dt = self.cursor.fetchone()
        return dt
    #任务执行状态 1 执行 2 完成 3失败
    def updateTask(self,data ):
        self.cursor.execute( common["update_task"].format( **data ) )
        self._conn.commit()
    def updatePrice(self,data):
        self.cursor.execute(common["update_price"].format(**data))
        self._conn.commit()
        print("\n/*产品价格更新成功:%d*/"%data["id"])

